package com.ztjy.dao;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;


public class HiveDAO {
    public static Dataset<Row> getUserRelation() {
        String sql = "select id from data_analysis.user_behavior where dt = 20180814 limit 10";
        return MySparkSession.getSparkSession().sql(sql);
    }
}
